package com.sxt.server.handler;

import com.lmax.disruptor.EventHandler;
import com.lmax.disruptor.WorkHandler;
import com.sxt.server.common.model.TranslatorDataWapper;


/**
 * 	抽象消费者处理，实现EventHandler接口，WorkHandler
 * @author Administrator
 *
 */

public abstract class MessageConsumer implements EventHandler<TranslatorDataWapper>, WorkHandler<TranslatorDataWapper>{
	 protected String consumerId;
     
	    public MessageConsumer(String consumerId) {
	        this.consumerId = consumerId;
	    }
	 
	    public String getConsumerId() {
	        return consumerId;
	    }
	 
	    public void setConsumerId(String consumerId) {
	        this.consumerId = consumerId;
	    }
}
